999c72be0468664c711159cd53deff79e62ee4a1,retrofit-adapters/rxjava/src/test/java/retrofit2/adapter/rxjava/ObservableTest.java,ObservableTest,bodySuccess404,#,62

Before Change


    server.enqueue(new MockResponse().setResponseCode(404));

    BlockingObservable<String> o = service.body().toBlocking();
    try {
      o.first();
      fail();
    } catch (RuntimeException e) {
      Throwable cause = e.getCause();
      assertThat(cause).isInstanceOf(HttpException.class).hasMessage("HTTP 404 Client Error");
    }
  }

After Change


    service.body().subscribe(subscriber);
    subscriber.assertNoValues();
    Throwable cause = subscriber.getOnErrorEvents().get(0);
    assertThat(cause).isInstanceOf(HttpException.class).hasMessage("HTTP 404 Client Error");
  }

  @Test public void bodyFailure() {